let OSS = require('ali-oss');
const express = require('express')
const cors = require('cors')
const app = express()
var multiparty = require('multiparty');
app.use(cors())
app.use(express.urlencoded())
const fs = require('fs')

let client = new OSS({
  // yourregion填写Bucket所在地域。以华东1（杭州）为例，Region填写为oss-cn-hangzhou。
  region: 'oss-cn-beijing',
  // 阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维，请登录RAM控制台创建RAM用户。
  accessKeyId: 'LTAI5tDadC8BW6P35KvtKzEj',
  accessKeySecret: 'gcv6la0Vj432ffqmMH2NATrzqbvcuS',
  bucket: 'landuoduo'
});

// 创建存储空间。
async function put(file,name) {
  try {
    // 填写Bucket名称。
    const result = await client.put(`test/${name}`, file);
    console.log(result);
  } catch (err) {
    console.log(err);
  }
}

app.post('/upload', (req, res) => {
  var form = new multiparty.Form();
  form.parse(req, function(err, fields, files) {
    if (err) {
      res.writeHead(400, { 'content-type': 'text/plain' })
      res.end('invalid request: ' + err.message)
      return;
    }
    files.imgs.forEach(file => {
      let name = file.originalFilename
      fs.readFile(file.path, function (err, data) {
        if (err) return console.log('读取文件失败：' + err.message)
        put(data, name)
      })
    })
    res.send('成功')
  });
})

app.get('/', (req, res) => {
  res.send('9090')
})
app.listen(3000)